

#include <stdio.h>
#include <unistd.h>


#include "mqtt_task.h"              // MQTT接口
#include "mqtt_light_constant.h"    //常量接口
#include "mqtt_api.h"

    // char strFormat[] = "{\"type\":\"mq3\",\"id\":%d,\"aout\":%d,\"dout\":%d}" ;



int publishMQ3(char* payload ){
    
    // 主题
    char *ptopic = "test/publish";  
                                            
    
    printf("test-anran0 %s %s ",ptopic, payload);
    // 发送数据 并返回发送状态
    int rc = MqttTaskPublish(ptopic, payload);                              // 发布消息
    
    // 下面注释的这段代码在验证mqtt日志功能正常后可以删除
    if (rc != 0)                                                            // 检查是否成功发布消息
    {
        printf("MQTT Publish failed!\r\n");                                 // 输出发布失败信息
        return 0;
    }
    printf("MQTT Publish OK\r\n");                                          // 输出发布成功信息
    return rc ; 
}

